package queue;

import java.util.concurrent.PriorityBlockingQueue;

/**
 * @author: 李德才
 * @description:
 * @create: 2020-12-13 21:06
 **/
public class Test_PriorityBlockingQueue {

  public static void main(String[] args) {

    /**
     * priorityBlockingQueue是一个无界队列，它没有限制，在内存允许的情况下可以无限添加元素；
     * 它又是具有优先级的队列，是通过构造函数传入的对象来判断，传入的对象必须实现comparable接口。
     */

    /**
     * 线程安全的 PriorityQueue ,使用  ReentrantLock 实现
     */
    PriorityBlockingQueue<Object> objects = new PriorityBlockingQueue<>();
    objects.add("c");
    objects.add("e");
    objects.add("b");
    objects.add("a");
    objects.add("d");
    objects.add("z");
  }
}
